package com.test.rabbitmq.topic;

public class TopicMain {

    public static void main(String[] args) {
//        Thread tp = new Thread(new Publisher());
//        try {
////            Thread.sleep(5 * 1000);
//            tp.start();
//            System.out.println("--------------------publish thread join.");
//            tp.join();
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        }
//        System.out.println("--------------------send over.");
        // consume start
        Thread tc1 = new Thread(new Consumer1());
        Thread tc2 = new Thread(new Consumer2());
        Thread tc3 = new Thread(new Consumer3());
        tc1.start();
        tc2.start();
        tc3.start();
    }
}
